package com.zzr.demo.redis.service;

/**
 * @author: xiaomi
 * @date: 2021/10/8
 * @description: 带有阻塞功能的消息队列
 */
public interface BlockMQService {

    /**
     * 增加消息
     *
     * @param msg
     * @return
     */
    boolean addMessage(String msg);

    /**
     * 带阻塞接受消息
     *
     * @return
     */
    String getMessageWithBlock();


    long size();
}
